package pl.edu.agh.inpema.core.queue;

import javax.jms.JMSException;

public interface Queue {

	public void startConnection() throws JMSException;
	public void closeConnection();
	
	public void createQueue(String analyzerName) throws JMSException;
	
	public QueueMessage getMessageForAnalyzer(String analyzerName, int timeout) throws JMSException;
	public void sendMessageToAnalyzer(String analyzerName, QueueMessage queueMessage) throws JMSException;
}
